package org.company.mars.kafka;

import java.util.Properties;

import org.company.earth.util.JsonUtil;

import com.fasterxml.jackson.databind.node.ObjectNode;

import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;

public class KafkaConsumer {
	
	
	
	public static void main(String[] args) {
		
	}
}
